package com.ywu.mq.standard.data;

import com.ywu.mq.sdk.domain.dto.YwuKafkaDto;
import com.ywu.mq.standard.dto.YwuKafkaTopicDto;
import com.ywu.mq.standard.entity.YwuKafkaTopicEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;

@Mapper
public interface YwuKafkaTopicRepository {
    void insertKafkaTopic(@Param("model") YwuKafkaTopicEntity entity);

    void deleteKafkaTopicById(@Param("model") YwuKafkaTopicEntity entity);

    YwuKafkaTopicEntity getEntity(@Param("model") YwuKafkaTopicEntity entity);

    List<YwuKafkaTopicEntity> queryList(@Param("model") YwuKafkaTopicDto dto);

    Integer queryListCount(@Param("model") YwuKafkaTopicDto ywuKafkaTopicDto);

    void updateEntity(@Param("model") YwuKafkaTopicEntity updateEntity);

    YwuKafkaTopicEntity queryEntityByAppIdPermission(@Param("model") YwuKafkaDto dto);
}
